const fs = require("fs");

//读取文件流
let rs = fs.createReadStream("./input.txt");
let str = ""; //文件内容
let count = 0; //读取文件次数
rs.on("data", function (data) {
    console.log("每次读取文件长度：" + data.length);
    str += data;
    count++;
});
rs.once("end", function () { //once只触发一次监听就不再触发
    console.log("读取文件次数：" + count);
    console.log("文件内容：\n" + str);
});

//写入文件流
let ws = fs.createWriteStream("./output.txt");
// for (var i=0; i<100; i++){
//     ws.write("这是我写入的数据...\n");
// }
// ws.end();
// ws.once("finish", function () {
//     console.log("写入数据成功！！！");
// });

//pipe读写流管道
rs.pipe(ws);
console.log("pipe执行成功！！！");